// 在CreateWithHisDataAsync方法开始处添加分布式锁
using var distributedLock = await _distributedLockProvider.AcquireLockAsync("refund_task_creation", TimeSpan.FromSeconds(30));

if (!distributedLock.IsAcquired)
{
    throw new InvalidOperationException("系统正在处理其他退费任务创建请求，请稍后重试");
}